package com.bossien.flink.interfaces;


/**
 * @author 胡春林
 * 获取执行器接口
 */
public interface IExecutionFactory {

    <T> T newInstance(Class<T> t);

    /**
     *
     * @param clazz
     * @param state 是否生产数据rabbimq
     * @return
     */
    boolean getRabbitInstance(Class clazz,boolean state);
}
